//package com.mbyte.easy.rabbitMQ;
//
//import com.mbyte.easy.config.RabbitMQConfig;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//
///**
// * @author zte
// * @since 2021/1/20 22:15
// */
//@Slf4j
//@Service
//public class MQSender {
//
//    @Autowired
//    private RabbitTemplate rabbitTemplate;
//
//    /**
//     * 简单模式
//     * @param msg
//     */
//    public void send(Object msg){
//        log.info("发送消息：" + msg);
//        rabbitTemplate.convertAndSend("queue",msg);
//    }
//
//    /**
//     * Fanout模式
//     * @param msg
//     */
//    public void sendFanout(Object msg){
//        log.info("发送消息：" + msg);
//        rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE, "" ,msg);
//    }
//
//    /**
//     * Topic模式
//     * @param msg
//     */
//    public void sendTopicOne(Object msg){
//        log.info("发送消息：" + msg);
//        rabbitTemplate.convertAndSend(RabbitMQConfig.TOPIC_EXCHANGE, "queue.red.massage" ,msg);
//    }
//    public void sendTopicTwo(Object msg){
//        log.info("发送消息：" + msg);
//        rabbitTemplate.convertAndSend(RabbitMQConfig.TOPIC_EXCHANGE, "object.queue.red" ,msg);
//    }
//
//}
